package org.example.lesson;

import java.io.IOException;
import java.util.Scanner;

/**
 * 和客户端进行互动
 */
public class TCPMsgServer extends TCPEchoServer {
    /**
     * 构造方法
     * @param port 服务端的端口号
     * @throws IOException
     */
    public TCPMsgServer(int port) throws IOException {
        super(port);
    }
    //实现一个简单聊天

    @Override
    protected String process(String request) {
        //打印客户端发来的内容
        System.out.println("->"+request);
        //获取响应的内容
        Scanner in=new Scanner(System.in);
        String response=in.nextLine();
        //返回响应内容
        return response;
    }

    public static void main(String[] args) throws IOException {
        TCPMsgServer server=new TCPMsgServer(9090);
        server.start();
    }
}
